// 云函数入口文件
const cloud = require('wx-server-sdk')

cloud.init({
  // API 调用都保持和云函数当前所在环境一致
  env: cloud.DYNAMIC_CURRENT_ENV
})

const db = cloud.database()

// 云函数入口函数
exports.main = async (event, context) => {
  const { fundCode, fundQuotient, OPENID_WEB } = event
  const { OPENID, UNIONID } = cloud.getWXContext()




  // 根据openid查询该用户是否已添加该基金 不再检查
  // let { data: existJJ } = await db.collection('zixuanjjs').where({
  //   openid: OPENID
  // }).get()

  // let isExist = existJJ.find(item => item.code == fundCode)
  // if (isExist) {
  //   return {
  //     error: '该基金已添加'
  //   }
  // }

  // 无需再检查
  // let { data } = await axios({
  //   url: `http://fundgz.1234567.com.cn/js/${fundCode}.js`,
  //   method: 'get'
  // })

  // if (data) {
  //   data = jsonpToJson(data)
  // }

  // 添加入自选
  await db.collection('zixuanjjs').add({
    data: {
      code: fundCode,
      openid: OPENID || OPENID_WEB,
      unionid: UNIONID,
      quotient: fundQuotient
    }
  })

  return {
    res: 'ok'
  }

}